/**
 * 
 */
package com.qolome.order.message;

import lombok.extern.slf4j.Slf4j;

/**
 * @Description: RabbitMQServer
 * @author 姜锋
 * @date 2020年1月21日 下午3:28:08
 * @version V1.0
 */
// @Component
@Slf4j
public class MqConsumer {
	//手动创建队列
	//@RabbitListener(queues = "manualQueue")
	public void manualQueue(String msg) {
		log.info("manualQueue:{}", msg);
	}
	// 自动创建队列
	//@RabbitListener(queuesToDeclare = @Queue("autoQueue"))
	public void autoQueue(String msg) {
		log.info("autoQueue:{}", msg);
	}
	// 自动创建队列并绑定交换机
	//@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("order@Exchange"), value = @Queue("orderQueue")))
	public void orderQueue(String msg) {
		log.info("orderQueue:{}", msg);
	}
	//@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("order@Exchange"), key = "computer", value = @Queue("computerQueue")))
	public void computerQueue(String msg) {
		log.info("computerQueue:{}", msg);
	}
	//@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("order@Exchange"), key = "furniture", value = @Queue("furnitureQueue")))
	public void furnitureQueue(String msg) {
		log.info("furnitureQueue:{}", msg);
	}
	
	//@RabbitListener(bindings = @QueueBinding(exchange = @Exchange("order@Exchange"), key = "estate", value = @Queue("estateQueue")))
	public void estateQueue(String msg) {
		log.info("estateQueue:{}", msg);
	}
}
